package HDFS;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;

/**
 *文件上传
 */
public class Test_01 {
    public static void main(String[] args) throws IOException {
        //获取配置文件
        Configuration conf = new Configuration();
        //设置配置到conf对象
        conf.set("fs.defaultFS","hdfs://bigdata211:9000");
        //通过FileSystem类获取hadoop文件系统对象
        FileSystem fs = FileSystem.get(conf);
        //本地路径
        Path src = new Path("E:\\公司制度\\北亚企安考勤制度20190103.doc");
        //HDFS上传路径
        Path target = new Path("/data/北亚企安考勤制度20190103.doc");
        //调用FileSystem类的方法（需要两个参数，都是hadoop.fs的Path类）上传过程
        fs.copyFromLocalFile(src,target);
        //关流
        fs.close();
        //打印输出
        System.out.println("上传成功！");


    }

}
